package cn.sx.stream.sender.output;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 当前sender模块中 所有定义的output类型的通道 全部交给这个接口管理
 */
public interface StreamOutputSource {
    //所谓的管理功能 就是能够让stream组件帮助我们通过建立这个接口的代理
    //负责所有通道对象的获取功能
    @Output("stream-sender-output01")
    MessageChannel getStreamOutput01();

    @Output("stream-sender-output02")
    MessageChannel getStreamOutput02();
}
